package com.quanliang.org.crawlerquanliang.core;

import com.quanliang.org.crawlerquanliang.pojo.Data;

import java.util.concurrent.LinkedBlockingDeque;

/**
 * 存储URL和数据的容器
 *
 * @author FYM
 * @data 2022/8/27 1:42
 */
public class Container {

    /**
     * 数据生产者消费者队列
     */
    public static final LinkedBlockingDeque<Data> dataQueue = new LinkedBlockingDeque<>();

    /**
     * 生产者(多线程爬虫)是否结束
     */
    public static volatile boolean isOver = false;

    /**
     * URL队列 任务启动自动初始化
     */
    public static final LinkedBlockingDeque<String> urlQueue = new LinkedBlockingDeque<>();

    /**
     * 任务已结束
     */
    public static volatile boolean isEnd = false;

    /**
     *  爬虫起始时间
     */
    public static long beginTime;
}
